//本地消息队列
/**
 * 可以添加主题
 * 可以消费消息
 */
var Amq = {
    newCreate() {
        var self = {}
        /**
         * @param {Object}
         */
        self.hashmap = {}
        /**
         * 发送消息
         * @param {String} 主题 
         */
        self.emit = function (主题, 值) {
            if (!self.hashmap.hasOwnProperty(主题)) {
                self.hashmap[主题] = []
            }
            self.hashmap[主题].push(值)
        }
		/**
		 * 监听消息
		 */
        self.on = function (主题) {
            if (!self.hashmap.hasOwnProperty(主题)) {
                self.hashmap[主题] = []
                return null;
            }      
            return (self.hashmap[主题].length==0)?null:self.hashmap[主题].shift()
        }           
        self.isEmpty = function (主题) {
            if (!self.hashmap.hasOwnProperty(主题)) {
                return true;
            } else {
                return (self.hashmap[主题].length == 0);
            }
        }
        return self;
    }
}
export default Amq;
// let mq =Tmq.newCreate();
// mq.emit("msg1","点对1")
// mq.emit("msg1","点对2")
// mq.emit("msg1","点对3")
// mq.emit("msg1","点对4")
// console.log("获取消息",mq.isEmpty("msg1"))
// console.log("获取消息",mq.on("msg1"))
// console.log("获取消息",mq.on("msg1"))
// console.log("获取消息",mq.on("msg1"))
// console.log("获取消息",mq.on("msg1"))
// console.log("获取消息",mq.on("msg1"))
// console.log("获取消息",mq.isEmpty("msg1"))